//package com.ocom.xfrecode.config;
//
//import org.apache.shardingsphere.api.sharding.standard.PreciseShardingAlgorithm;
//import org.apache.shardingsphere.api.sharding.standard.PreciseShardingValue;
//
//import java.util.Collection;
//
///**
// * @Description: 自定义标准分库策略
// * @Author: 朱晖
// * @Date: 2022/7/5
// **/
//public class ShardingConfig implements PreciseShardingAlgorithm<String> {
//
//	@Override
//	public String doSharding(Collection<String> databaseNames, PreciseShardingValue<String> shardingValue) {
//
//		/**
//		 * databaseNames 所有分片库的集合
//		 * shardingValue 为分片属性，其中 logicTableName 为逻辑表，columnName 分片健（字段），value 为从 SQL 中解析出的分片健的值
//		 */
//		for (String databaseName : databaseNames) {
//			if(databaseName.endsWith(shardingValue.getValue())){
//				return databaseName;
//			}
////			Integer value = shardingValue.getValue().intValue();
////			String ends = "0";
////			if(value>500){
////				ends="1";
////			}
////			if (databaseName.endsWith(ends)) {
////				return databaseName;
////			}
//		}
//		throw new IllegalArgumentException();
//	}
////	@Override
////	public String doSharding(Collection<String> databaseNames, PreciseShardingValue<Long> shardingValue) {
////
////		/**
////		 * databaseNames 所有分片库的集合
////		 * shardingValue 为分片属性，其中 logicTableName 为逻辑表，columnName 分片健（字段），value 为从 SQL 中解析出的分片健的值
////		 */
////		for (String databaseName : databaseNames) {
////			Integer value = shardingValue.getValue().intValue();
////			String ends = "0";
////			if(value>500){
////				ends="1";
////			}
////			if (databaseName.endsWith(ends)) {
////				return databaseName;
////			}
////		}
////		throw new IllegalArgumentException();
////	}
//}